package demo.components.kafka.demo;

import demo.components.kafka.KafkaConsumer;
import demo.components.kafka.KafkaMessageHandler;

public class Handler  implements KafkaMessageHandler{

    @Override
    public void processMessage(KafkaConsumer consumer, String msg, long messageOffset) {
        System.out.println("////msg"+msg);

    }

}
